package com.tongcao.cn.mq.handle;

import com.tongcao.cn.mq.to.AsyncMsg;

/**
 * @Author:tongcao
 * @Date:2019/1/25 16:36
 * Description:
 */
public interface IMessageHandle {


    /**
     * tag
     *
     * @return
     */
    String getSubExpression();

    /**
     * @param asyncMsg
     * @return
     */
    boolean consume(AsyncMsg asyncMsg);
}
